# config.py
KAFKA_CONFIG = {
    'bootstrap_servers': '222.201.56.93:9092',  # 您的Kafka地址
    'topic': 'wordcount-topic',
    'group_id': 'wordcount-group'
}